#ifndef __M_WORKER_H__
#define __M_WORKER_H__
#include "muduo/net/EventLoopThread.h"
#include "../mqcommon/mq_logger.hpp"
#include "../mqcommon/mq_helper.hpp"
#include "../mqcommon/mq_threadpool.hpp"

namespace mymq
{
    class Async
    {
    public:
        using ptr = std::shared_ptr<Async>;
        // 网络I/O事件监控，异步循环线程
        muduo::net::EventLoopThread _loopthread;
        // 收到消息后进行异步处理的工作线程线程池
        ThreadPool _pool;
    };
}

#endif